package sql

import org.apache.spark.sql.{Dataset, SparkSession}

object sql02_wc {

  def main(args: Array[String]): Unit = {


    val ss: SparkSession = SparkSession.builder()
      .master("local[*]")
      .appName("sql02")
      .getOrCreate()


    val ds: Dataset[String] = ss.read.textFile("data/user.tb")

    val resDs: Dataset[String] = ds.where("value = 'bb'")



    resDs.show()
  }

}
